package com.wcgksoft.source.DataCi;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * @author 阿良
 * @version 1.0.0
 * @ClassName ServerHandler2.java
 * @Description 处理器2 阿良
 * @createTime 2020年05月02日 15:42:00
 */
public class ServerHandler2 extends ChannelInboundHandlerAdapter {
  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    ByteBuf buf = Unpooled.buffer();
    buf.writeBytes(new byte[]{00});
    //写消息：先得到channel，在写如通道然后flush刷新通道把消息发出去。
    ctx.channel().writeAndFlush(buf);
  }
}
